package com.dhcc.activemq.producer;
 
import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jms.core.JmsMessagingTemplate;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import com.google.gson.Gson;
 
/**
 * 
* <p>标题: MqProducer.java</p>
* <p>业务描述:健康管理平台</p>
* <p>公司:东华软件股份公司</p>
* <p>版权:dhcc2013</p>
* @author 胡凯
* @date 2019年7月30日
* @version V1.0
 */
@Component
@RestController
public class MqProducer {
 
 
    @Autowired
    private JmsMessagingTemplate jmsMessagingTemplate;
 
 
    /**
     * 发送字符串消息队列
     *
     * @param queueName 队列名称
     * @param message   字符串
     */
    @RequestMapping("/queue")
    public void sendStringQueue(String queueName, String message) {
        this.jmsMessagingTemplate.convertAndSend(new ActiveMQQueue(queueName), message);
    }
    public void send(String queueName, String message) {
      this.jmsMessagingTemplate.convertAndSend(new ActiveMQQueue(queueName), message);
  }
    /**
     * 发送字符串消息topic
     *
     * @param queueName topic名称
     * @param message   字符串
     */
    @RequestMapping("/topic")
    public void sendStringTopic(String topicName, String message) {
    	this.jmsMessagingTemplate.convertAndSend(new ActiveMQTopic(topicName), message);
    }
    
 
}